private static enum AbstractListenerWriteProcessor.State extends java.lang.Enum<AbstractListenerWriteProcessor.State>
Processor
to be in.
UNSUBSCRIBED | v +--- REQUESTED -------------> RECEIVED ---+ | ^ ^ | | | | | | + ------ WRITING <------+ | | | | | v | +--------------> COMPLETED <--------------+
Enum Constant and Description |
---|
COMPLETED |
RECEIVED |
REQUESTED |
UNSUBSCRIBED |
WRITING |
Modifier and Type | Method and Description |
---|---|
<T> void |
onComplete(AbstractListenerWriteProcessor<T> processor) |
<T> void |
onError(AbstractListenerWriteProcessor<T> processor,
java.lang.Throwable ex) |
<T> void |
onNext(AbstractListenerWriteProcessor<T> processor,
T data) |
<T> void |
onSubscribe(AbstractListenerWriteProcessor<T> processor,
Subscription subscription) |
<T> void |
onWritePossible(AbstractListenerWriteProcessor<T> processor) |
static AbstractListenerWriteProcessor.State |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static AbstractListenerWriteProcessor.State[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final AbstractListenerWriteProcessor.State UNSUBSCRIBED
public static final AbstractListenerWriteProcessor.State REQUESTED
public static final AbstractListenerWriteProcessor.State RECEIVED
public static final AbstractListenerWriteProcessor.State WRITING
public static final AbstractListenerWriteProcessor.State COMPLETED
public static AbstractListenerWriteProcessor.State[] values()
for (AbstractListenerWriteProcessor.State c : AbstractListenerWriteProcessor.State.values()) System.out.println(c);
public static AbstractListenerWriteProcessor.State valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic <T> void onSubscribe(AbstractListenerWriteProcessor<T> processor, Subscription subscription)
public <T> void onNext(AbstractListenerWriteProcessor<T> processor, T data)
public <T> void onError(AbstractListenerWriteProcessor<T> processor, java.lang.Throwable ex)
public <T> void onComplete(AbstractListenerWriteProcessor<T> processor)
public <T> void onWritePossible(AbstractListenerWriteProcessor<T> processor)